package cn.lingyangwl.framework.mqtt.service;

import cn.lingyangwl.framework.mq.base.BaseMqMessage;
import cn.lingyangwl.framework.mq.base.enums.QosEnum;

/**
 * @author shenguangyang
 */
public interface MqttSendExpandService {
    <T extends BaseMqMessage> void send(String topic, QosEnum qosEnum, T message) throws Exception;
}
